[INFO] fetching crate google-cloud-pubsub 1.1.0...
[INFO] fixing google-cloud-pubsub-1.1.0 against try#622891a4e29178280638a6b63a8908bde2c0c854+cargoflags=-Zfix-edition=start=2015 for pr-157817-2
[INFO] extracting crate google-cloud-pubsub 1.1.0 into /workspace/builds/worker-5-tc1/source
[INFO] started tweaking crates.io crate google-cloud-pubsub 1.1.0
[INFO] finished tweaking crates.io crate google-cloud-pubsub 1.1.0
[INFO] tweaked toml for crates.io crate google-cloud-pubsub 1.1.0 written to /workspace/builds/worker-5-tc1/source/Cargo.toml
[INFO] validating manifest of crates.io crate google-cloud-pubsub 1.1.0 on toolchain 622891a4e29178280638a6b63a8908bde2c0c854
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+622891a4e29178280638a6b63a8908bde2c0c854" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] crate crates.io crate google-cloud-pubsub 1.1.0 already has a lockfile, it will not be regenerated
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+622891a4e29178280638a6b63a8908bde2c0c854" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Updating crates.io index
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded prost v0.14.3
[INFO] [stderr]   Downloaded prost-derive v0.14.3
[INFO] [stderr]   Downloaded prost-types v0.14.3
[INFO] [stderr]   Downloaded uuid v1.23.2
[INFO] [stderr]   Downloaded google-cloud-iam-v1 v1.10.0
[INFO] [stderr]   Downloaded google-cloud-type v1.5.0
[INFO] [stderr]   Downloaded log v0.4.31
[INFO] [stderr]   Downloaded tracing-opentelemetry v0.33.0
[INFO] [stderr]   Downloaded wasm-bindgen-futures v0.4.72
[INFO] [stderr]   Downloaded opentelemetry v0.32.0
[INFO] [stderr]   Downloaded crypto-common v0.2.2
[INFO] [stderr]   Downloaded cmov v0.5.4
[INFO] [stderr]   Downloaded google-cloud-rpc v1.5.0
[INFO] [stderr]   Downloaded digest v0.11.3
[INFO] [stderr]   Downloaded hybrid-array v0.4.12
[INFO] [stderr]   Downloaded google-cloud-wkt v1.5.0
[INFO] [stderr]   Downloaded google-cloud-gax-internal v0.7.14
[INFO] [stderr]   Downloaded google-cloud-gax v1.11.0
[INFO] [stderr]   Downloaded jni-macros v0.22.4
[INFO] [stderr]   Downloaded opentelemetry-semantic-conventions v0.32.0
[INFO] [stderr]   Downloaded webpki-root-certs v1.0.7
[INFO] [stderr]   Downloaded jni v0.22.4
[INFO] [stderr]   Downloaded google-cloud-auth v1.11.0
[INFO] [stderr]   Downloaded opentelemetry_sdk v0.32.1
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/source:/opt/rustwide/workdir:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-m" "1610612736" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:3a6becf2bc8dde7f3fa57ede90e4f284e72d296796fc446bbb1e2c7cc0530151" "sleep" "infinity", kill_on_drop: false }`
[INFO] [stdout] 76adf9c26249b57c13daea1b47f53b8893dd92750699a755d208547f0acfb7a6
[INFO] running `Command { std: "docker" "start" "76adf9c26249b57c13daea1b47f53b8893dd92750699a755d208547f0acfb7a6", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-w" "/opt/rustwide/workdir" "--user" "0:0" "76adf9c26249b57c13daea1b47f53b8893dd92750699a755d208547f0acfb7a6" "/opt/rustwide/cargo-home/bin/cargo" "+622891a4e29178280638a6b63a8908bde2c0c854" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "76adf9c26249b57c13daea1b47f53b8893dd92750699a755d208547f0acfb7a6", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=" "-e" "RUSTDOCFLAGS=" "-w" "/opt/rustwide/workdir" "--user" "0:0" "76adf9c26249b57c13daea1b47f53b8893dd92750699a755d208547f0acfb7a6" "/opt/rustwide/cargo-home/bin/cargo" "+622891a4e29178280638a6b63a8908bde2c0c854" "fix" "--allow-no-vcs" "--allow-dirty" "--frozen" "--all" "--all-targets" "--message-format=json" "-Zfix-edition=start=2015", kill_on_drop: false }`
[INFO] [stderr]    Compiling serde_core v1.0.228
[INFO] [stderr]    Compiling serde v1.0.228
[INFO] [stderr]     Checking futures-core v0.3.32
[INFO] [stderr]     Checking futures-sink v0.3.32
[INFO] [stderr]    Compiling syn v2.0.117
[INFO] [stderr]     Checking futures-task v0.3.32
[INFO] [stderr]    Compiling cc v1.2.63
[INFO] [stderr]     Checking tracing-core v0.1.36
[INFO] [stderr]    Compiling fs_extra v1.3.0
[INFO] [stderr]    Compiling dunce v1.0.5
[INFO] [stderr]    Compiling aws-lc-rs v1.17.0
[INFO] [stderr]     Checking hashbrown v0.15.5
[INFO] [stderr]     Checking indexmap v2.14.0
[INFO] [stderr]     Checking futures-channel v0.3.32
[INFO] [stderr]    Compiling thiserror v2.0.18
[INFO] [stderr]    Compiling strsim v0.11.1
[INFO] [stderr]    Compiling rustls v0.23.40
[INFO] [stderr]     Checking log v0.4.31
[INFO] [stderr]    Compiling serde_json v1.0.150
[INFO] [stderr]     Checking typenum v1.20.1
[INFO] [stderr]     Checking ipnet v2.12.0
[INFO] [stderr]     Checking powerfmt v0.2.0
[INFO] [stderr]     Checking memchr v2.8.1
[INFO] [stderr]     Checking sync_wrapper v1.0.2
[INFO] [stderr]     Checking num-conv v0.2.2
[INFO] [stderr]     Checking rand_core v0.10.1
[INFO] [stderr]     Checking time-core v0.1.8
[INFO] [stderr]    Compiling getrandom v0.4.2
[INFO] [stderr]    Compiling zerocopy v0.8.50
[INFO] [stderr]     Checking openssl-probe v0.2.1
[INFO] [stderr]    Compiling cmake v0.1.58
[INFO] [stderr]    Compiling semver v1.0.28
[INFO] [stderr]     Checking rustls-native-certs v0.8.4
[INFO] [stderr]    Compiling anyhow v1.0.102
[INFO] [stderr]    Compiling rustc_version v0.4.1
[INFO] [stderr]     Checking cpufeatures v0.3.0
[INFO] [stderr]     Checking cmov v0.5.4
[INFO] [stderr]    Compiling either v1.16.0
[INFO] [stderr]    Compiling num-traits v0.2.19
[INFO] [stderr]     Checking ctutils v0.4.2
[INFO] [stderr]     Checking getrandom v0.3.4
[INFO] [stderr]    Compiling itertools v0.14.0
[INFO] [stderr]     Checking hybrid-array v0.4.12
[INFO] [stderr]     Checking rand_core v0.9.5
[INFO] [stderr]    Compiling aws-lc-sys v0.41.0
[INFO] [stderr]     Checking chacha20 v0.10.0
[INFO] [stderr]     Checking bitflags v2.12.1
[INFO] [stderr]     Checking futures-io v0.3.32
[INFO] [stderr]     Checking sharded-slab v0.1.7
[INFO] [stderr]     Checking rand v0.10.1
[INFO] [stderr]     Checking block-buffer v0.12.0
[INFO] [stderr]     Checking crypto-common v0.2.2
[INFO] [stderr]     Checking deranged v0.5.8
[INFO] [stderr]     Checking digest v0.11.3
[INFO] [stderr]    Compiling google-cloud-auth v1.11.0
[INFO] [stderr]     Checking thread_local v1.1.9
[INFO] [stderr]     Checking iana-time-zone v0.1.65
[INFO] [stderr]     Checking tracing-subscriber v0.3.23
[INFO] [stderr]     Checking sha2 v0.11.0
[INFO] [stderr]     Checking chrono v0.4.44
[INFO] [stderr]     Checking hmac v0.13.0
[INFO] [stderr]    Compiling google-cloud-gax-internal v0.7.14
[INFO] [stderr]     Checking hex v0.4.3
[INFO] [stderr]     Checking opentelemetry-semantic-conventions v0.32.0
[INFO] [stderr]     Checking uuid v1.23.2
[INFO] [stderr]     Checking time v0.3.47
[INFO] [stderr]    Compiling synstructure v0.13.2
[INFO] [stderr]    Compiling darling_core v0.23.0
[INFO] [stderr]    Compiling serde_derive v1.0.228
[INFO] [stderr]    Compiling zerofrom-derive v0.1.7
[INFO] [stderr]    Compiling yoke-derive v0.8.2
[INFO] [stderr]    Compiling zerovec-derive v0.11.3
[INFO] [stderr]    Compiling futures-macro v0.3.32
[INFO] [stderr]    Compiling displaydoc v0.2.6
[INFO] [stderr]    Compiling tokio-macros v2.7.0
[INFO] [stderr]    Compiling tracing-attributes v0.1.31
[INFO] [stderr]     Checking futures-util v0.3.32
[INFO] [stderr]    Compiling thiserror-impl v2.0.18
[INFO] [stderr]     Checking zerofrom v0.1.8
[INFO] [stderr]     Checking yoke v0.8.2
[INFO] [stderr]    Compiling pin-project-internal v1.1.13
[INFO] [stderr]     Checking zerovec v0.11.6
[INFO] [stderr]     Checking zerotrie v0.2.4
[INFO] [stderr]     Checking tinystr v0.8.3
[INFO] [stderr]     Checking tracing v0.1.44
[INFO] [stderr]     Checking potential_utf v0.1.5
[INFO] [stderr]     Checking icu_locale_core v2.2.0
[INFO] [stderr]     Checking icu_collections v2.2.0
[INFO] [stderr]    Compiling darling_macro v0.23.0
[INFO] [stderr]     Checking pin-project v1.1.13
[INFO] [stderr]     Checking ppv-lite86 v0.2.21
[INFO] [stderr]    Compiling prost-derive v0.14.3
[INFO] [stderr]    Compiling darling v0.23.0
[INFO] [stderr]     Checking opentelemetry v0.32.0
[INFO] [stderr]    Compiling serde_with_macros v3.20.0
[INFO] [stderr]     Checking rand_chacha v0.9.0
[INFO] [stderr]     Checking rand v0.9.4
[INFO] [stderr]    Compiling async-trait v0.1.89
[INFO] [stderr]     Checking icu_provider v2.2.0
[INFO] [stderr]     Checking icu_normalizer v2.2.0
[INFO] [stderr]     Checking bytes v1.11.1
[INFO] [stderr]     Checking icu_properties v2.2.0
[INFO] [stderr]     Checking serde_with v3.20.0
[INFO] [stderr]     Checking futures v0.3.32
[INFO] [stderr]     Checking serde_urlencoded v0.7.1
[INFO] [stderr]     Checking futures-executor v0.3.32
[INFO] [stderr]     Checking opentelemetry_sdk v0.32.1
[INFO] [stderr]     Checking tracing-opentelemetry v0.33.0
[INFO] [stderr]     Checking tokio v1.52.3
[INFO] [stderr]     Checking http v1.4.1
[INFO] [stderr]     Checking prost v0.14.3
[INFO] [stderr]     Checking prost-types v0.14.3
[INFO] [stderr]     Checking idna_adapter v1.2.2
[INFO] [stderr]     Checking idna v1.1.0
[INFO] [stderr]     Checking http-body v1.0.1
[INFO] [stderr]     Checking http-body-util v0.1.3
[INFO] [stderr]     Checking url v2.5.8
[INFO] [stderr]     Checking google-cloud-wkt v1.5.0
[INFO] [stderr]     Checking google-cloud-rpc v1.5.0
[INFO] [stderr]     Checking google-cloud-type v1.5.0
[INFO] [stderr]     Checking tokio-util v0.7.18
[INFO] [stderr]     Checking tokio-stream v0.1.18
[INFO] [stderr]     Checking google-cloud-gax v1.11.0
[INFO] [stderr]     Checking h2 v0.4.14
[INFO] [stderr]     Checking tower v0.5.3
[INFO] [stderr]     Checking tower-http v0.6.11
[INFO] [stderr]     Checking hyper v1.10.1
[INFO] [stderr]     Checking hyper-util v0.1.20
[INFO] [stderr]     Checking hyper-timeout v0.5.2
[INFO] [stderr]     Checking rustls-webpki v0.103.13
[INFO] [stderr]     Checking tokio-rustls v0.26.4
[INFO] [stderr]     Checking rustls-platform-verifier v0.7.0
[INFO] [stderr]     Checking hyper-rustls v0.27.9
[INFO] [stderr]     Checking tonic v0.14.6
[INFO] [stderr]     Checking reqwest v0.13.4
[INFO] [stderr]     Checking tonic-prost v0.14.6
[INFO] [stderr]     Checking google-cloud-iam-v1 v1.10.0
[INFO] [stderr]     Checking google-cloud-pubsub v1.1.0 (/opt/rustwide/workdir)
[INFO] [stdout] error: functions used as tests can not have any arguments
[INFO] [stdout]    --> src/subscriber/builder.rs:301:11
[INFO] [stdout]     |
[INFO] [stdout] 301 |       async fn clamp_ack_deadline(v: Duration, want: i32) -> anyhow::Result<()> {
[INFO] [stdout]     |  ___________^
[INFO] [stdout] 302 | |         let builder = Subscribe::new(
[INFO] [stdout] 303 | |             test_inner().await?,
[INFO] [stdout] 304 | |             "projects/my-project/subscriptions/my-subscription".to_string(),
[INFO] [stdout] ...   |
[INFO] [stdout] 311 | |         Ok(())
[INFO] [stdout] 312 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: functions used as tests can not have any arguments
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:322:11
[INFO] [stdout]     |
[INFO] [stdout] 322 |       async fn process_attempt_error_retryable_code_without_error_info(
[INFO] [stdout]     |  ___________^
[INFO] [stdout] 323 | |         code: Code,
[INFO] [stdout] 324 | |     ) -> anyhow::Result<()> {
[INFO] [stdout] 325 | |         let err = Arc::new(Error::service(
[INFO] [stdout] ...   |
[INFO] [stdout] 335 | |         Ok(())
[INFO] [stdout] 336 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: functions used as tests can not have any arguments
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:344:11
[INFO] [stdout]     |
[INFO] [stdout] 344 |       async fn process_attempt_error_retryable_code_with_error_info(
[INFO] [stdout]     |  ___________^
[INFO] [stdout] 345 | |         code: Code,
[INFO] [stdout] 346 | |     ) -> anyhow::Result<()> {
[INFO] [stdout] 347 | |         let info = ErrorInfo::new().set_metadata([
[INFO] [stdout] ...   |
[INFO] [stdout] 367 | |         Ok(())
[INFO] [stdout] 368 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: functions used as tests can not have any arguments
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:382:11
[INFO] [stdout]     |
[INFO] [stdout] 382 |       async fn process_attempt_error_non_retryable_code_without_error_info(
[INFO] [stdout]     |  ___________^
[INFO] [stdout] 383 | |         code: Code,
[INFO] [stdout] 384 | |     ) -> anyhow::Result<()> {
[INFO] [stdout] 385 | |         let err = Arc::new(Error::service(
[INFO] [stdout] ...   |
[INFO] [stdout] 409 | |         Ok(())
[INFO] [stdout] 410 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: functions used as tests can not have any arguments
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:424:11
[INFO] [stdout]     |
[INFO] [stdout] 424 |       async fn process_attempt_error_non_retryable_code_permanent_failure(
[INFO] [stdout]     |  ___________^
[INFO] [stdout] 425 | |         code: Code,
[INFO] [stdout] 426 | |     ) -> anyhow::Result<()> {
[INFO] [stdout] 427 | |         let info =
[INFO] [stdout] ...   |
[INFO] [stdout] 453 | |         Ok(())
[INFO] [stdout] 454 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: functions used as tests can not have any arguments
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:468:11
[INFO] [stdout]     |
[INFO] [stdout] 468 |       async fn process_attempt_error_non_retryable_code_transient_failure(
[INFO] [stdout]     |  ___________^
[INFO] [stdout] 469 | |         code: Code,
[INFO] [stdout] 470 | |     ) -> anyhow::Result<()> {
[INFO] [stdout] 471 | |         let info = ErrorInfo::new().set_metadata([(test_id(1), "TRANSIENT_FAILURE_OTHER")]);
[INFO] [stdout] ...   |
[INFO] [stdout] 486 | |         Ok(())
[INFO] [stdout] 487 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `pubsub_grpc_mock` in this scope
[INFO] [stdout]    --> src/subscriber/transport.rs:100:9
[INFO] [stdout]     |
[INFO] [stdout] 100 |     use pubsub_grpc_mock::google::pubsub::v1;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `pubsub_grpc_mock`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `pubsub_grpc_mock`, use `cargo add pubsub_grpc_mock` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `pubsub_grpc_mock`
[INFO] [stdout]    --> src/subscriber/client.rs:182:9
[INFO] [stdout]     |
[INFO] [stdout] 182 |     use pubsub_grpc_mock::{MockSubscriber, start};
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `pubsub_grpc_mock`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `pubsub_grpc_mock`, use `cargo add pubsub_grpc_mock` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `pubsub_grpc_mock`
[INFO] [stdout]    --> src/subscriber/transport.rs:101:9
[INFO] [stdout]     |
[INFO] [stdout] 101 |     use pubsub_grpc_mock::{MockSubscriber, start};
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `pubsub_grpc_mock`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `pubsub_grpc_mock`, use `cargo add pubsub_grpc_mock` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `google_cloud_test_macros`
[INFO] [stdout]    --> src/publisher/client.rs:187:9
[INFO] [stdout]     |
[INFO] [stdout] 187 |     use google_cloud_test_macros::tokio_test_no_panics;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `google_cloud_test_macros`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `google_cloud_test_macros`, use `cargo add google_cloud_test_macros` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `mockall`
[INFO] [stdout]    --> src/publisher/client.rs:188:9
[INFO] [stdout]     |
[INFO] [stdout] 188 |     use mockall::Sequence;
[INFO] [stdout]     |         ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `rand` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:189:9
[INFO] [stdout]     |
[INFO] [stdout] 189 |     use rand::{RngExt, distr::Alphanumeric};
[INFO] [stdout]     |         ^^^^ use of unresolved module or unlinked crate `rand`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `rand`, use `cargo add rand` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `rand`
[INFO] [stdout]    --> src/publisher/client.rs:189:9
[INFO] [stdout]     |
[INFO] [stdout] 189 |     use rand::{RngExt, distr::Alphanumeric};
[INFO] [stdout]     |         ^^^^ use of unresolved module or unlinked crate `rand`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `rand`, use `cargo add rand` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `google_cloud_test_macros`
[INFO] [stdout]    --> src/publisher/actor.rs:532:9
[INFO] [stdout]     |
[INFO] [stdout] 532 |     use google_cloud_test_macros::tokio_test_no_panics;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `google_cloud_test_macros`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `google_cloud_test_macros`, use `cargo add google_cloud_test_macros` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `mockall`
[INFO] [stdout]    --> src/publisher/actor.rs:533:9
[INFO] [stdout]     |
[INFO] [stdout] 533 |     use mockall::Sequence;
[INFO] [stdout]     |         ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `rand` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:534:9
[INFO] [stdout]     |
[INFO] [stdout] 534 |     use rand::{RngExt, distr::Alphanumeric};
[INFO] [stdout]     |         ^^^^ use of unresolved module or unlinked crate `rand`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `rand`, use `cargo add rand` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `rand`
[INFO] [stdout]    --> src/publisher/actor.rs:534:9
[INFO] [stdout]     |
[INFO] [stdout] 534 |     use rand::{RngExt, distr::Alphanumeric};
[INFO] [stdout]     |         ^^^^ use of unresolved module or unlinked crate `rand`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `rand`, use `cargo add rand` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `google_cloud_test_macros`
[INFO] [stdout]    --> src/publisher/batch.rs:143:9
[INFO] [stdout]     |
[INFO] [stdout] 143 |     use google_cloud_test_macros::tokio_test_no_panics;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `google_cloud_test_macros`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `google_cloud_test_macros`, use `cargo add google_cloud_test_macros` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `google_cloud_rpc` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:211:9
[INFO] [stdout]     |
[INFO] [stdout] 211 |     use google_cloud_rpc::model::ErrorInfo;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `google_cloud_rpc`
[INFO] [stdout]     |
[INFO] [stdout] help: there is a crate or module with a similar name
[INFO] [stdout]     |
[INFO] [stdout] 211 -     use google_cloud_rpc::model::ErrorInfo;
[INFO] [stdout] 211 +     use google_cloud_gax::model::ErrorInfo;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `test_case`
[INFO] [stdout]    --> src/subscriber/builder.rs:222:9
[INFO] [stdout]     |
[INFO] [stdout] 222 |     use test_case::test_case;
[INFO] [stdout]     |         ^^^^^^^^^ use of unresolved module or unlinked crate `test_case`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `test_case`, use `cargo add test_case` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `mockall`
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:212:9
[INFO] [stdout]     |
[INFO] [stdout] 212 |     use mockall::Sequence;
[INFO] [stdout]     |         ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `test_case`
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:214:9
[INFO] [stdout]     |
[INFO] [stdout] 214 |     use test_case::test_case;
[INFO] [stdout]     |         ^^^^^^^^^ use of unresolved module or unlinked crate `test_case`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `test_case`, use `cargo add test_case` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `google_cloud_test_macros`
[INFO] [stdout]   --> src/subscriber/keepalive.rs:52:9
[INFO] [stdout]    |
[INFO] [stdout] 52 |     use google_cloud_test_macros::tokio_test_no_panics;
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `google_cloud_test_macros`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `google_cloud_test_macros`, use `cargo add google_cloud_test_macros` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `super::super::leaser::tests::MockLeaser`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:162:9
[INFO] [stdout]     |
[INFO] [stdout] 162 |     use super::super::leaser::tests::MockLeaser;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^----------
[INFO] [stdout]     |                                      |
[INFO] [stdout]     |                                      no `MockLeaser` in `subscriber::leaser::tests`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `google_cloud_test_macros`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:165:9
[INFO] [stdout]     |
[INFO] [stdout] 165 |     use google_cloud_test_macros::tokio_test_no_panics;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `google_cloud_test_macros`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `google_cloud_test_macros`, use `cargo add google_cloud_test_macros` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `test_case`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:168:9
[INFO] [stdout]     |
[INFO] [stdout] 168 |     use test_case::test_case;
[INFO] [stdout]     |         ^^^^^^^^^ use of unresolved module or unlinked crate `test_case`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `test_case`, use `cargo add test_case` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `super::super::leaser::tests::MockLeaser`
[INFO] [stdout]    --> src/subscriber/lease_state.rs:383:9
[INFO] [stdout]     |
[INFO] [stdout] 383 |     use super::super::leaser::tests::MockLeaser;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^----------
[INFO] [stdout]     |                                      |
[INFO] [stdout]     |                                      no `MockLeaser` in `subscriber::leaser::tests`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `super::super::stub::tests::MockStub`
[INFO] [stdout]    --> src/subscriber/leaser.rs:282:9
[INFO] [stdout]     |
[INFO] [stdout] 282 |     use super::super::stub::tests::MockStub;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^--------
[INFO] [stdout]     |                                    |
[INFO] [stdout]     |                                    no `MockStub` in `subscriber::stub::tests`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `pubsub_grpc_mock` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:471:9
[INFO] [stdout]     |
[INFO] [stdout] 471 |     use pubsub_grpc_mock::google::pubsub::v1;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `pubsub_grpc_mock`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `pubsub_grpc_mock`, use `cargo add pubsub_grpc_mock` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `google_cloud_test_macros`
[INFO] [stdout]    --> src/subscriber/message_stream.rs:470:9
[INFO] [stdout]     |
[INFO] [stdout] 470 |     use google_cloud_test_macros::tokio_test_no_panics;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `google_cloud_test_macros`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `google_cloud_test_macros`, use `cargo add google_cloud_test_macros` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `pubsub_grpc_mock`
[INFO] [stdout]    --> src/subscriber/message_stream.rs:472:9
[INFO] [stdout]     |
[INFO] [stdout] 472 |     use pubsub_grpc_mock::{MockSubscriber, start};
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `pubsub_grpc_mock`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `pubsub_grpc_mock`, use `cargo add pubsub_grpc_mock` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `test_case`
[INFO] [stdout]    --> src/subscriber/message_stream.rs:473:9
[INFO] [stdout]     |
[INFO] [stdout] 473 |     use test_case::test_case;
[INFO] [stdout]     |         ^^^^^^^^^ use of unresolved module or unlinked crate `test_case`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `test_case`, use `cargo add test_case` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `test_case`
[INFO] [stdout]    --> src/subscriber/retry_policy.rs:137:9
[INFO] [stdout]     |
[INFO] [stdout] 137 |     use test_case::test_case;
[INFO] [stdout]     |         ^^^^^^^^^ use of unresolved module or unlinked crate `test_case`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `test_case`, use `cargo add test_case` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `super::super::stub::tests::MockStub`
[INFO] [stdout]    --> src/subscriber/stream.rs:158:9
[INFO] [stdout]     |
[INFO] [stdout] 158 |     use super::super::stub::tests::MockStub;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^--------
[INFO] [stdout]     |                                    |
[INFO] [stdout]     |                                    no `MockStub` in `subscriber::stub::tests`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `google_cloud_test_macros`
[INFO] [stdout]    --> src/subscriber/stream.rs:165:9
[INFO] [stdout]     |
[INFO] [stdout] 165 |     use google_cloud_test_macros::tokio_test_no_panics;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `google_cloud_test_macros`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `google_cloud_test_macros`, use `cargo add google_cloud_test_macros` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `test_case`
[INFO] [stdout]   --> src/retry_policy.rs:95:9
[INFO] [stdout]    |
[INFO] [stdout] 95 |     use test_case::test_case;
[INFO] [stdout]    |         ^^^^^^^^^ use of unresolved module or unlinked crate `test_case`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `test_case`, use `cargo add test_case` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:195:5
[INFO] [stdout]     |
[INFO] [stdout] 195 |     mockall::mock! {
[INFO] [stdout]     |     ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:209:5
[INFO] [stdout]     |
[INFO] [stdout] 209 |     mockall::mock! {
[INFO] [stdout]     |     ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:543:5
[INFO] [stdout]     |
[INFO] [stdout] 543 |     mockall::mock! {
[INFO] [stdout]     |     ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:557:5
[INFO] [stdout]     |
[INFO] [stdout] 557 |     mockall::mock! {
[INFO] [stdout]     |     ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/publisher/batch.rs:146:5
[INFO] [stdout]     |
[INFO] [stdout] 146 |     mockall::mock! {
[INFO] [stdout]     |     ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:217:5
[INFO] [stdout]     |
[INFO] [stdout] 217 |     mockall::mock! {
[INFO] [stdout]     |     ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:225:5
[INFO] [stdout]     |
[INFO] [stdout] 225 |     mockall::mock! {
[INFO] [stdout]     |     ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:231:5
[INFO] [stdout]     |
[INFO] [stdout] 231 |     mockall::mock! {
[INFO] [stdout]     |     ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1325:17
[INFO] [stdout]      |
[INFO] [stdout] 1325 |                 anyhow::bail!("expected batch {i}/{NUM_BATCHES}");
[INFO] [stdout]      |                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1371:17
[INFO] [stdout]      |
[INFO] [stdout] 1371 |                 anyhow::bail!("expected batch {i}/{NUM_BATCHES}");
[INFO] [stdout]      |                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:291:5
[INFO] [stdout]     |
[INFO] [stdout] 291 |     mockall::mock! {
[INFO] [stdout]     |     ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:305:5
[INFO] [stdout]     |
[INFO] [stdout] 305 |     mockall::mock! {
[INFO] [stdout]     |     ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:658:17
[INFO] [stdout]     |
[INFO] [stdout] 658 |                 anyhow::bail!("expected message {i}/6")
[INFO] [stdout]     |                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:724:13
[INFO] [stdout]     |
[INFO] [stdout] 724 |             anyhow::bail!("expected message")
[INFO] [stdout]     |             ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:768:17
[INFO] [stdout]     |
[INFO] [stdout] 768 |                 anyhow::bail!("expected message {i}/6")
[INFO] [stdout]     |                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:832:17
[INFO] [stdout]     |
[INFO] [stdout] 832 |                 anyhow::bail!("expected message {i}")
[INFO] [stdout]     |                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:839:17
[INFO] [stdout]     |
[INFO] [stdout] 839 |                 anyhow::bail!("expected message {i}")
[INFO] [stdout]     |                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:847:17
[INFO] [stdout]     |
[INFO] [stdout] 847 |                 anyhow::bail!("expected message {i}")
[INFO] [stdout]     |                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:941:17
[INFO] [stdout]     |
[INFO] [stdout] 941 |                 anyhow::bail!("expected message {i}/6")
[INFO] [stdout]     |                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:974:17
[INFO] [stdout]     |
[INFO] [stdout] 974 |                 anyhow::bail!("expected message {i}/2")
[INFO] [stdout]     |                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1028:17
[INFO] [stdout]      |
[INFO] [stdout] 1028 |                 anyhow::bail!("expected message {i}/6")
[INFO] [stdout]      |                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1071:17
[INFO] [stdout]      |
[INFO] [stdout] 1071 |                 anyhow::bail!("expected message {i}/3")
[INFO] [stdout]      |                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1719:17
[INFO] [stdout]      |
[INFO] [stdout] 1719 |                 anyhow::bail!("expected message {i}/5")
[INFO] [stdout]      |                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1783:17
[INFO] [stdout]      |
[INFO] [stdout] 1783 |                 anyhow::bail!("expected message {i}/5")
[INFO] [stdout]      |                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1890:17
[INFO] [stdout]      |
[INFO] [stdout] 1890 |                 anyhow::bail!("expected message {i}/5")
[INFO] [stdout]      |                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/subscriber/stream.rs:167:5
[INFO] [stdout]     |
[INFO] [stdout] 167 |     mockall::mock! {
[INFO] [stdout]     |     ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]   --> src/subscriber/stub.rs:64:5
[INFO] [stdout]    |
[INFO] [stdout] 64 |     mockall::mock! {
[INFO] [stdout]    |     ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/subscriber/lease_state.rs:838:23
[INFO] [stdout]     |
[INFO] [stdout] 838 |         let mut seq = mockall::Sequence::new();
[INFO] [stdout]     |                       ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/subscriber/lease_state.rs:894:23
[INFO] [stdout]     |
[INFO] [stdout] 894 |         let mut seq = mockall::Sequence::new();
[INFO] [stdout]     |                       ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1393:23
[INFO] [stdout]      |
[INFO] [stdout] 1393 |         let mut seq = mockall::Sequence::new();
[INFO] [stdout]      |                       ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1440:23
[INFO] [stdout]      |
[INFO] [stdout] 1440 |         let mut seq = mockall::Sequence::new();
[INFO] [stdout]      |                       ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:536:23
[INFO] [stdout]     |
[INFO] [stdout] 536 |         let mut seq = mockall::Sequence::new();
[INFO] [stdout]     |                       ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:646:23
[INFO] [stdout]     |
[INFO] [stdout] 646 |         let mut seq = mockall::Sequence::new();
[INFO] [stdout]     |                       ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:773:23
[INFO] [stdout]     |
[INFO] [stdout] 773 |         let mut seq = mockall::Sequence::new();
[INFO] [stdout]     |                       ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1247:23
[INFO] [stdout]      |
[INFO] [stdout] 1247 |         let mut seq = mockall::Sequence::new();
[INFO] [stdout]      |                       ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1296:23
[INFO] [stdout]      |
[INFO] [stdout] 1296 |         let mut seq = mockall::Sequence::new();
[INFO] [stdout]      |                       ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1365:23
[INFO] [stdout]      |
[INFO] [stdout] 1365 |         let mut seq = mockall::Sequence::new();
[INFO] [stdout]      |                       ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/subscriber/stream.rs:303:23
[INFO] [stdout]     |
[INFO] [stdout] 303 |         let mut seq = mockall::Sequence::new();
[INFO] [stdout]     |                       ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `mockall` in this scope
[INFO] [stdout]    --> src/subscriber/stream.rs:350:23
[INFO] [stdout]     |
[INFO] [stdout] 350 |         let mut seq = mockall::Sequence::new();
[INFO] [stdout]     |                       ^^^^^^^ use of unresolved module or unlinked crate `mockall`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `mockall`, use `cargo add mockall` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:342:50
[INFO] [stdout]     |
[INFO] [stdout] 342 |         let client = GapicPublisher::from_stub::<MockGapicPublisher>(mock_arc);
[INFO] [stdout]     |                                                  ^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: src/generated/gapic_dataplane/client.rs:21:1
[INFO] [stdout]     |
[INFO] [stdout]  21 | pub struct Publisher {
[INFO] [stdout]     | -------------------- similarly named struct `GapicPublisher` defined here
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 342 -         let client = GapicPublisher::from_stub::<MockGapicPublisher>(mock_arc);
[INFO] [stdout] 342 +         let client = GapicPublisher::from_stub::<GapicPublisher>(mock_arc);
[INFO] [stdout]     |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]     |
[INFO] [stdout] 334 |     async fn publisher_publish_successfully_with_arc<MockGapicPublisher>() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                     ++++++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find type `MockRetryPolicy` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:241:27
[INFO] [stdout]     |
[INFO] [stdout] 241 |     fn to_retry_policy(m: MockRetryPolicy) -> Arc<dyn RetryPolicy> {
[INFO] [stdout]     |                           ^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/google-cloud-gax-1.11.0/src/retry_policy.rs:71:1
[INFO] [stdout]     |
[INFO] [stdout]  71 | pub trait RetryPolicy: Send + Sync + std::fmt::Debug {
[INFO] [stdout]     | ---------------------------------------------------- similarly named trait `RetryPolicy` defined here
[INFO] [stdout]     |
[INFO] [stdout] help: a trait with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 241 -     fn to_retry_policy(m: MockRetryPolicy) -> Arc<dyn RetryPolicy> {
[INFO] [stdout] 241 +     fn to_retry_policy(m: RetryPolicy) -> Arc<dyn RetryPolicy> {
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/keepalive.rs:91:22
[INFO] [stdout]     |
[INFO] [stdout]  91 |         tokio::time::advance(DELTA).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:244:22
[INFO] [stdout]     |
[INFO] [stdout] 244 |         tokio::time::advance(FLUSH_START).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:288:22
[INFO] [stdout]     |
[INFO] [stdout] 288 |         tokio::time::advance(FLUSH_START).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:340:26
[INFO] [stdout]     |
[INFO] [stdout] 340 |             tokio::time::advance(FLUSH_START).await;
[INFO] [stdout]     |                          ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:360:26
[INFO] [stdout]     |
[INFO] [stdout] 360 |             tokio::time::advance(FLUSH_PERIOD).await;
[INFO] [stdout]     |                          ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:390:26
[INFO] [stdout]     |
[INFO] [stdout] 390 |             tokio::time::advance(FLUSH_PERIOD).await;
[INFO] [stdout]     |                          ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:464:26
[INFO] [stdout]     |
[INFO] [stdout] 464 |             tokio::time::advance(EXTEND_START).await;
[INFO] [stdout]     |                          ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:479:26
[INFO] [stdout]     |
[INFO] [stdout] 479 |             tokio::time::advance(EXTEND_PERIOD).await;
[INFO] [stdout]     |                          ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:511:26
[INFO] [stdout]     |
[INFO] [stdout] 511 |             tokio::time::advance(EXTEND_PERIOD).await;
[INFO] [stdout]     |                          ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:744:30
[INFO] [stdout]     |
[INFO] [stdout] 744 |                 tokio::time::advance(Duration::from_millis(100)).await;
[INFO] [stdout]     |                              ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:754:30
[INFO] [stdout]     |
[INFO] [stdout] 754 |                 tokio::time::advance(Duration::from_millis(100)).await;
[INFO] [stdout]     |                              ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:806:22
[INFO] [stdout]     |
[INFO] [stdout] 806 |         tokio::time::advance(EXTEND_START).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:815:22
[INFO] [stdout]     |
[INFO] [stdout] 815 |         tokio::time::advance(EXTEND_PERIOD).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_state/at_least_once.rs:316:22
[INFO] [stdout]     |
[INFO] [stdout] 316 |         tokio::time::advance(Duration::from_secs(5)).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_state/at_least_once.rs:532:22
[INFO] [stdout]     |
[INFO] [stdout] 532 |         tokio::time::advance(DELTA * 2).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_state/at_least_once.rs:549:22
[INFO] [stdout]     |
[INFO] [stdout] 549 |         tokio::time::advance(MAX_LEASE - DELTA).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_state/at_least_once.rs:563:22
[INFO] [stdout]     |
[INFO] [stdout] 563 |         tokio::time::advance(DELTA * 2).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_state/at_least_once.rs:614:22
[INFO] [stdout]     |
[INFO] [stdout] 614 |         tokio::time::advance(MAX_LEASE_EXTENSION - Duration::from_secs(1)).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_state/exactly_once.rs:504:22
[INFO] [stdout]     |
[INFO] [stdout] 504 |         tokio::time::advance(Duration::from_secs(5)).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_state/exactly_once.rs:897:22
[INFO] [stdout]     |
[INFO] [stdout] 897 |         tokio::time::advance(MAX_LEASE_EXTENSION - Duration::from_secs(1)).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_state.rs:471:22
[INFO] [stdout]     |
[INFO] [stdout] 471 |         tokio::time::advance(Duration::from_secs(61)).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/lease_state.rs:492:22
[INFO] [stdout]     |
[INFO] [stdout] 492 |         tokio::time::advance(Duration::from_secs(61)).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1418:22
[INFO] [stdout]      |
[INFO] [stdout] 1418 |         tokio::time::advance(DELTA * 2).await;
[INFO] [stdout]      |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]      |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]     --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]      |
[INFO] [stdout]   90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]      |                     ^^^^^^^
[INFO] [stdout]      |
[INFO] [stdout]     ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]      |
[INFO] [stdout]  564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]      |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1425:22
[INFO] [stdout]      |
[INFO] [stdout] 1425 |         tokio::time::advance(MAX_LEASE - DELTA).await;
[INFO] [stdout]      |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]      |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]     --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]      |
[INFO] [stdout]   90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]      |                     ^^^^^^^
[INFO] [stdout]      |
[INFO] [stdout]     ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]      |
[INFO] [stdout]  564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]      |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1429:22
[INFO] [stdout]      |
[INFO] [stdout] 1429 |         tokio::time::advance(DELTA * 2).await;
[INFO] [stdout]      |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]      |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]     --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]      |
[INFO] [stdout]   90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]      |                     ^^^^^^^
[INFO] [stdout]      |
[INFO] [stdout]     ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]      |
[INFO] [stdout]  564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]      |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1465:22
[INFO] [stdout]      |
[INFO] [stdout] 1465 |         tokio::time::advance(DELTA * 2).await;
[INFO] [stdout]      |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]      |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]     --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]      |
[INFO] [stdout]   90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]      |                     ^^^^^^^
[INFO] [stdout]      |
[INFO] [stdout]     ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]      |
[INFO] [stdout]  564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]      |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1472:22
[INFO] [stdout]      |
[INFO] [stdout] 1472 |         tokio::time::advance(MAX_LEASE - DELTA).await;
[INFO] [stdout]      |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]      |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]     --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]      |
[INFO] [stdout]   90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]      |                     ^^^^^^^
[INFO] [stdout]      |
[INFO] [stdout]     ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]      |
[INFO] [stdout]  564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]      |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1476:22
[INFO] [stdout]      |
[INFO] [stdout] 1476 |         tokio::time::advance(DELTA * 2).await;
[INFO] [stdout]      |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]      |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]     --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]      |
[INFO] [stdout]   90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]      |                     ^^^^^^^
[INFO] [stdout]      |
[INFO] [stdout]     ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]      |
[INFO] [stdout]  564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]      |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find type `MockLeaser` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:314:25
[INFO] [stdout]     |
[INFO] [stdout] 314 |     impl Leaser for Arc<MockLeaser> {
[INFO] [stdout]     |                         ^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]     |
[INFO] [stdout] 314 |     impl<MockLeaser> Leaser for Arc<MockLeaser> {
[INFO] [stdout]     |         ++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find type `MockLeaser` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:336:31
[INFO] [stdout]     |
[INFO] [stdout] 336 |     impl Leaser for Arc<Mutex<MockLeaser>> {
[INFO] [stdout]     |                               ^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]     |
[INFO] [stdout] 336 |     impl<MockLeaser> Leaser for Arc<Mutex<MockLeaser>> {
[INFO] [stdout]     |         ++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/message_stream.rs:854:22
[INFO] [stdout]     |
[INFO] [stdout] 854 |         tokio::time::advance(Duration::from_secs(10)).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1037:22
[INFO] [stdout]      |
[INFO] [stdout] 1037 |         tokio::time::advance(Duration::from_secs(10)).await;
[INFO] [stdout]      |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]      |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]     --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]      |
[INFO] [stdout]   90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]      |                     ^^^^^^^
[INFO] [stdout]      |
[INFO] [stdout]     ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]      |
[INFO] [stdout]  564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]      |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1130:22
[INFO] [stdout]      |
[INFO] [stdout] 1130 |         tokio::time::advance(KEEPALIVE_PERIOD).await;
[INFO] [stdout]      |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]      |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]     --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]      |
[INFO] [stdout]   90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]      |                     ^^^^^^^
[INFO] [stdout]      |
[INFO] [stdout]     ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]      |
[INFO] [stdout]  564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]      |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1143:22
[INFO] [stdout]      |
[INFO] [stdout] 1143 |         tokio::time::advance(4 * KEEPALIVE_PERIOD).await;
[INFO] [stdout]      |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]      |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]     --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]      |
[INFO] [stdout]   90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]      |                     ^^^^^^^
[INFO] [stdout]      |
[INFO] [stdout]     ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]      |
[INFO] [stdout]  564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]      |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1554:26
[INFO] [stdout]      |
[INFO] [stdout] 1554 |             tokio::time::advance(Duration::from_secs(1)).await;
[INFO] [stdout]      |                          ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]      |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]     --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]      |
[INFO] [stdout]   90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]      |                     ^^^^^^^
[INFO] [stdout]      |
[INFO] [stdout]     ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]      |
[INFO] [stdout]  564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]      |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `advance` in module `tokio::time`
[INFO] [stdout]    --> src/subscriber/stream.rs:271:22
[INFO] [stdout]     |
[INFO] [stdout] 271 |         tokio::time::advance(KEEPALIVE_PERIOD).await;
[INFO] [stdout]     |                      ^^^^^^^ not found in `tokio::time`
[INFO] [stdout]     |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/time/mod.rs:90:21
[INFO] [stdout]     |
[INFO] [stdout]  90 |     pub use clock::{advance, pause, resume};
[INFO] [stdout]     |                     ^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]    ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/macros/cfg.rs:564:19
[INFO] [stdout]     |
[INFO] [stdout] 564 |             #[cfg(feature = "test-util")]
[INFO] [stdout]     |                   --------------------- the item is gated behind the `test-util` feature
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `google_cloud_gax::backoff_policy::BackoffPolicy`
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:203:9
[INFO] [stdout]     |
[INFO] [stdout] 203 |     use google_cloud_gax::backoff_policy::BackoffPolicy;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `google_cloud_gax::throttle_result::ThrottleResult`
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:210:9
[INFO] [stdout]     |
[INFO] [stdout] 210 |     use google_cloud_gax::throttle_result::ThrottleResult;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `google_cloud_gax::retry_state::RetryState`
[INFO] [stdout]    --> src/subscriber/leaser.rs:286:9
[INFO] [stdout]     |
[INFO] [stdout] 286 |     use google_cloud_gax::retry_state::RetryState;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `google_cloud_gax::backoff_policy::BackoffPolicy`
[INFO] [stdout]    --> src/subscriber/stream.rs:162:9
[INFO] [stdout]     |
[INFO] [stdout] 162 |     use google_cloud_gax::backoff_policy::BackoffPolicy;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `google_cloud_gax::retry_state::RetryState`
[INFO] [stdout]    --> src/subscriber/stream.rs:164:9
[INFO] [stdout]     |
[INFO] [stdout] 164 |     use google_cloud_gax::retry_state::RetryState;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:303:24
[INFO] [stdout]     |
[INFO] [stdout] 303 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 303 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 303 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:335:24
[INFO] [stdout]     |
[INFO] [stdout] 335 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 335 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 335 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:417:24
[INFO] [stdout]     |
[INFO] [stdout] 417 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 417 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 417 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:455:24
[INFO] [stdout]     |
[INFO] [stdout] 455 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 455 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 455 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:487:24
[INFO] [stdout]     |
[INFO] [stdout] 487 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 487 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 487 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:533:24
[INFO] [stdout]     |
[INFO] [stdout] 533 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 533 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 533 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:582:24
[INFO] [stdout]     |
[INFO] [stdout] 582 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 582 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 582 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:616:24
[INFO] [stdout]     |
[INFO] [stdout] 616 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 616 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 616 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:649:24
[INFO] [stdout]     |
[INFO] [stdout] 649 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 649 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 649 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:681:24
[INFO] [stdout]     |
[INFO] [stdout] 681 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 681 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 681 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:780:24
[INFO] [stdout]     |
[INFO] [stdout] 780 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 780 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 780 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisherWithFuture` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:828:24
[INFO] [stdout]     |
[INFO] [stdout] 828 |         let mut mock = MockGapicPublisherWithFuture::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisherWithFuture`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisherWithFuture` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:889:24
[INFO] [stdout]     |
[INFO] [stdout] 889 |         let mut mock = MockGapicPublisherWithFuture::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisherWithFuture`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:939:24
[INFO] [stdout]     |
[INFO] [stdout] 939 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 939 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 939 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:989:24
[INFO] [stdout]     |
[INFO] [stdout] 989 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 989 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 989 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]     --> src/publisher/client.rs:1023:24
[INFO] [stdout]      |
[INFO] [stdout] 1023 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]      |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]      |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]      |
[INFO] [stdout] 1023 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 1023 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]     --> src/publisher/client.rs:1058:24
[INFO] [stdout]      |
[INFO] [stdout] 1058 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]      |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]      |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]      |
[INFO] [stdout] 1058 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 1058 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]     --> src/publisher/client.rs:1090:24
[INFO] [stdout]      |
[INFO] [stdout] 1090 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]      |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]      |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]      |
[INFO] [stdout] 1090 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 1090 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]     --> src/publisher/client.rs:1130:24
[INFO] [stdout]      |
[INFO] [stdout] 1130 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]      |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]      |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]      |
[INFO] [stdout] 1130 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 1130 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]     --> src/publisher/client.rs:1168:24
[INFO] [stdout]      |
[INFO] [stdout] 1168 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]      |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]      |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]      |
[INFO] [stdout] 1168 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 1168 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisherWithFuture` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:719:24
[INFO] [stdout]     |
[INFO] [stdout] 719 |         let mut mock = MockGapicPublisherWithFuture::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisherWithFuture`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisherWithFuture` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:756:24
[INFO] [stdout]     |
[INFO] [stdout] 756 |         let mut mock = MockGapicPublisherWithFuture::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisherWithFuture`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisherWithFuture` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:796:24
[INFO] [stdout]     |
[INFO] [stdout] 796 |         let mut mock = MockGapicPublisherWithFuture::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisherWithFuture`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisherWithFuture` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:841:24
[INFO] [stdout]     |
[INFO] [stdout] 841 |         let mut mock = MockGapicPublisherWithFuture::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisherWithFuture`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisherWithFuture` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:907:24
[INFO] [stdout]     |
[INFO] [stdout] 907 |         let mut mock = MockGapicPublisherWithFuture::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisherWithFuture`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:971:24
[INFO] [stdout]     |
[INFO] [stdout] 971 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 971 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 971 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:996:24
[INFO] [stdout]     |
[INFO] [stdout] 996 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 996 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 996 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]     --> src/publisher/actor.rs:1020:24
[INFO] [stdout]      |
[INFO] [stdout] 1020 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]      |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]      |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]      |
[INFO] [stdout] 1020 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 1020 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]     --> src/publisher/actor.rs:1059:24
[INFO] [stdout]      |
[INFO] [stdout] 1059 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]      |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]      |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]      |
[INFO] [stdout] 1059 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 1059 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]     --> src/publisher/actor.rs:1098:24
[INFO] [stdout]      |
[INFO] [stdout] 1098 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]      |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]      |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]      |
[INFO] [stdout] 1098 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 1098 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]     --> src/publisher/actor.rs:1132:24
[INFO] [stdout]      |
[INFO] [stdout] 1132 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]      |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]      |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]      |
[INFO] [stdout] 1132 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 1132 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/batch.rs:171:24
[INFO] [stdout]     |
[INFO] [stdout] 171 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 171 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 171 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/batch.rs:212:24
[INFO] [stdout]     |
[INFO] [stdout] 212 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 212 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 212 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockBackoffPolicy` in this scope
[INFO] [stdout]    --> src/subscriber/stream.rs:305:32
[INFO] [stdout]     |
[INFO] [stdout] 305 |         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout]     |                                ^^^^^^^^^^^^^^^^^ use of undeclared type `MockBackoffPolicy`
[INFO] [stdout]     |
[INFO] [stdout] help: a trait with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 305 -         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout] 305 +         let mut mock_backoff = BackoffPolicy::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockBackoffPolicy` in this scope
[INFO] [stdout]    --> src/subscriber/stream.rs:352:32
[INFO] [stdout]     |
[INFO] [stdout] 352 |         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout]     |                                ^^^^^^^^^^^^^^^^^ use of undeclared type `MockBackoffPolicy`
[INFO] [stdout]     |
[INFO] [stdout] help: a trait with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 352 -         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout] 352 +         let mut mock_backoff = BackoffPolicy::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `rand` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:260:9
[INFO] [stdout]     |
[INFO] [stdout] 260 |         rand::rng()
[INFO] [stdout]     |         ^^^^ use of unresolved module or unlinked crate `rand`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `rand`, use `cargo add rand` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:368:24
[INFO] [stdout]     |
[INFO] [stdout] 368 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 368 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 368 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:385:20
[INFO] [stdout]     |
[INFO] [stdout] 385 |         let mock = MockGapicPublisher::new();
[INFO] [stdout]     |                    ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 385 -         let mock = MockGapicPublisher::new();
[INFO] [stdout] 385 +         let mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/publisher/client.rs:405:9
[INFO] [stdout]     |
[INFO] [stdout] 405 |         for rx in handles.into_iter() {
[INFO] [stdout]     |         ^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:567:20
[INFO] [stdout]     |
[INFO] [stdout] 567 |         let mock = MockGapicPublisher::new();
[INFO] [stdout]     |                    ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 567 -         let mock = MockGapicPublisher::new();
[INFO] [stdout] 567 +         let mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/publisher/client.rs:576:9
[INFO] [stdout]     |
[INFO] [stdout] 576 |         Ok(())
[INFO] [stdout]     |         ^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:733:24
[INFO] [stdout]     |
[INFO] [stdout] 733 |         let mut mock = MockGapicPublisher::new();
[INFO] [stdout]     |                        ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 733 -         let mut mock = MockGapicPublisher::new();
[INFO] [stdout] 733 +         let mut mock = GapicPublisher::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/publisher/client.rs:762:9
[INFO] [stdout]     |
[INFO] [stdout] 762 |         for msg in messages {
[INFO] [stdout]     |         ^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `rand` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:601:9
[INFO] [stdout]     |
[INFO] [stdout] 601 |         rand::rng()
[INFO] [stdout]     |         ^^^^ use of unresolved module or unlinked crate `rand`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `rand`, use `cargo add rand` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:701:48
[INFO] [stdout]     |
[INFO] [stdout] 701 |         let client = GapicPublisher::from_stub(MockGapicPublisher::new());
[INFO] [stdout]     |                                                ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 701 -         let client = GapicPublisher::from_stub(MockGapicPublisher::new());
[INFO] [stdout] 701 +         let client = GapicPublisher::from_stub(GapicPublisher::new());
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockGapicPublisher` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:893:43
[INFO] [stdout]     |
[INFO] [stdout] 893 |                 GapicPublisher::from_stub(MockGapicPublisher::new()),
[INFO] [stdout]     |                                           ^^^^^^^^^^^^^^^^^^ use of undeclared type `MockGapicPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 893 -                 GapicPublisher::from_stub(MockGapicPublisher::new()),
[INFO] [stdout] 893 +                 GapicPublisher::from_stub(GapicPublisher::new()),
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockRpc` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:493:24
[INFO] [stdout]     |
[INFO] [stdout] 493 |         let mut mock = MockRpc::new();
[INFO] [stdout]     |                        ^^^^^^^ use of undeclared type `MockRpc`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockRpc` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:532:24
[INFO] [stdout]     |
[INFO] [stdout] 532 |         let mut mock = MockRpc::new();
[INFO] [stdout]     |                        ^^^^^^^ use of undeclared type `MockRpc`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockRpc` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:582:24
[INFO] [stdout]     |
[INFO] [stdout] 582 |         let mut mock = MockRpc::new();
[INFO] [stdout]     |                        ^^^^^^^ use of undeclared type `MockRpc`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockBackoffPolicy` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:601:32
[INFO] [stdout]     |
[INFO] [stdout] 601 |         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout]     |                                ^^^^^^^^^^^^^^^^^ use of undeclared type `MockBackoffPolicy`
[INFO] [stdout]     |
[INFO] [stdout] help: a trait with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 601 -         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout] 601 +         let mut mock_backoff = BackoffPolicy::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockRpc` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:633:24
[INFO] [stdout]     |
[INFO] [stdout] 633 |         let mut mock = MockRpc::new();
[INFO] [stdout]     |                        ^^^^^^^ use of undeclared type `MockRpc`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockBackoffPolicy` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:658:32
[INFO] [stdout]     |
[INFO] [stdout] 658 |         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout]     |                                ^^^^^^^^^^^^^^^^^ use of undeclared type `MockBackoffPolicy`
[INFO] [stdout]     |
[INFO] [stdout] help: a trait with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 658 -         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout] 658 +         let mut mock_backoff = BackoffPolicy::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockRpc` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:696:24
[INFO] [stdout]     |
[INFO] [stdout] 696 |         let mut mock = MockRpc::new();
[INFO] [stdout]     |                        ^^^^^^^ use of undeclared type `MockRpc`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockRpc` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:742:24
[INFO] [stdout]     |
[INFO] [stdout] 742 |         let mut mock = MockRpc::new();
[INFO] [stdout]     |                        ^^^^^^^ use of undeclared type `MockRpc`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockRetryPolicy` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:754:32
[INFO] [stdout]     |
[INFO] [stdout] 754 |         let mut retry_policy = MockRetryPolicy::new();
[INFO] [stdout]     |                                ^^^^^^^^^^^^^^^ use of undeclared type `MockRetryPolicy`
[INFO] [stdout]     |
[INFO] [stdout] help: a trait with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 754 -         let mut retry_policy = MockRetryPolicy::new();
[INFO] [stdout] 754 +         let mut retry_policy = RetryPolicy::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state/at_least_once.rs:326:9
[INFO] [stdout]     |
[INFO] [stdout] 326 |         assert_eq!(leases.last_extension(&test_id(2)), Some(later));
[INFO] [stdout]     |         ^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state/at_least_once.rs:575:9
[INFO] [stdout]     |
[INFO] [stdout] 575 |         Ok(())
[INFO] [stdout]     |         ^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state/at_least_once.rs:629:9
[INFO] [stdout]     |
[INFO] [stdout] 629 |         Ok(())
[INFO] [stdout]     |         ^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state/exactly_once.rs:514:9
[INFO] [stdout]     |
[INFO] [stdout] 514 |         assert_eq!(leases.last_extension(&test_id(2)), Some(later));
[INFO] [stdout]     |         ^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state/exactly_once.rs:671:9
[INFO] [stdout]     |
[INFO] [stdout] 671 |         Ok(())
[INFO] [stdout]     |         ^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state/exactly_once.rs:715:9
[INFO] [stdout]     |
[INFO] [stdout] 715 |         Ok(())
[INFO] [stdout]     |         ^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state/exactly_once.rs:913:9
[INFO] [stdout]     |
[INFO] [stdout] 913 |         Ok(())
[INFO] [stdout]     |         ^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state.rs:497:9
[INFO] [stdout]     |
[INFO] [stdout] 497 |         assert_eq!(flattened.ack_ids, test_ids(2..3));
[INFO] [stdout]     |         ^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state.rs:594:9
[INFO] [stdout]     |
[INFO] [stdout] 594 |         assert_eq!(
[INFO] [stdout]     |         ^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state.rs:688:9
[INFO] [stdout]     |
[INFO] [stdout] 688 |         assert_eq!(
[INFO] [stdout]     |         ^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state.rs:789:9
[INFO] [stdout]     |
[INFO] [stdout] 789 |         assert_eq!(
[INFO] [stdout]     |         ^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state.rs:830:9
[INFO] [stdout]     |
[INFO] [stdout] 830 |         assert!(
[INFO] [stdout]     |         ^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state.rs:886:9
[INFO] [stdout]     |
[INFO] [stdout] 886 |         for i in 5..10 {
[INFO] [stdout]     |         ^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state.rs:957:9
[INFO] [stdout]     |
[INFO] [stdout] 957 |         for i in 0..5 {
[INFO] [stdout]     |         ^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/lease_state.rs:990:9
[INFO] [stdout]     |
[INFO] [stdout] 990 |         assert_eq!(
[INFO] [stdout]     |         ^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1075:9
[INFO] [stdout]      |
[INFO] [stdout] 1075 |         assert_eq!(start.elapsed(), Duration::from_secs(7));
[INFO] [stdout]      |         ^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1113:9
[INFO] [stdout]      |
[INFO] [stdout] 1113 |         assert_eq!(start.elapsed(), FLUSH_START);
[INFO] [stdout]      |         ^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1151:9
[INFO] [stdout]      |
[INFO] [stdout] 1151 |         assert_eq!(start.elapsed(), FLUSH_START);
[INFO] [stdout]      |         ^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1190:9
[INFO] [stdout]      |
[INFO] [stdout] 1190 |         assert_eq!(start.elapsed(), FLUSH_START);
[INFO] [stdout]      |         ^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1228:9
[INFO] [stdout]      |
[INFO] [stdout] 1228 |         assert_eq!(start.elapsed(), FLUSH_START);
[INFO] [stdout]      |         ^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1260:9
[INFO] [stdout]      |
[INFO] [stdout] 1260 |         assert_eq!(start.elapsed(), FLUSH_START);
[INFO] [stdout]      |         ^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1292:9
[INFO] [stdout]      |
[INFO] [stdout] 1292 |         assert_eq!(start.elapsed(), FLUSH_START);
[INFO] [stdout]      |         ^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: `else` clause of `let...else` does not diverge
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1324:61
[INFO] [stdout]      |
[INFO] [stdout] 1324 |               let Some(ack_ids) = ack_id_rx.recv().await else {
[INFO] [stdout]      |  _____________________________________________________________^
[INFO] [stdout] 1325 | |                 anyhow::bail!("expected batch {i}/{NUM_BATCHES}");
[INFO] [stdout] 1326 | |             };
[INFO] [stdout]      | |_____________^ expected `!`, found `()`
[INFO] [stdout]      |
[INFO] [stdout]      = note:   expected type `!`
[INFO] [stdout]              found unit type `()`
[INFO] [stdout]      = help: try adding a diverging expression, such as `return` or `panic!(..)`
[INFO] [stdout]      = help: ...or use `match` instead of `let...else`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1339:9
[INFO] [stdout]      |
[INFO] [stdout] 1339 |         Ok(())
[INFO] [stdout]      |         ^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: `else` clause of `let...else` does not diverge
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1370:61
[INFO] [stdout]      |
[INFO] [stdout] 1370 |               let Some(ack_ids) = ack_id_rx.recv().await else {
[INFO] [stdout]      |  _____________________________________________________________^
[INFO] [stdout] 1371 | |                 anyhow::bail!("expected batch {i}/{NUM_BATCHES}");
[INFO] [stdout] 1372 | |             };
[INFO] [stdout]      | |_____________^ expected `!`, found `()`
[INFO] [stdout]      |
[INFO] [stdout]      = note:   expected type `!`
[INFO] [stdout]              found unit type `()`
[INFO] [stdout]      = help: try adding a diverging expression, such as `return` or `panic!(..)`
[INFO] [stdout]      = help: ...or use `match` instead of `let...else`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1385:9
[INFO] [stdout]      |
[INFO] [stdout] 1385 |         Ok(())
[INFO] [stdout]      |         ^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1432:9
[INFO] [stdout]      |
[INFO] [stdout] 1432 |         Ok(())
[INFO] [stdout]      |         ^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1479:9
[INFO] [stdout]      |
[INFO] [stdout] 1479 |         Ok(())
[INFO] [stdout]      |         ^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockLeaser` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:316:13
[INFO] [stdout]     |
[INFO] [stdout] 316 |             MockLeaser::ack(self, ack_ids).await
[INFO] [stdout]     |             ^^^^^^^^^^ use of undeclared type `MockLeaser`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockLeaser` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:319:13
[INFO] [stdout]     |
[INFO] [stdout] 319 |             MockLeaser::nack(self, ack_ids).await
[INFO] [stdout]     |             ^^^^^^^^^^ use of undeclared type `MockLeaser`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockLeaser` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:322:13
[INFO] [stdout]     |
[INFO] [stdout] 322 |             MockLeaser::extend(self, ack_ids).await
[INFO] [stdout]     |             ^^^^^^^^^^ use of undeclared type `MockLeaser`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockLeaser` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:325:13
[INFO] [stdout]     |
[INFO] [stdout] 325 |             MockLeaser::confirmed_ack(self, ack_ids).await
[INFO] [stdout]     |             ^^^^^^^^^^ use of undeclared type `MockLeaser`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockLeaser` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:328:13
[INFO] [stdout]     |
[INFO] [stdout] 328 |             MockLeaser::confirmed_nack(self, ack_ids).await
[INFO] [stdout]     |             ^^^^^^^^^^ use of undeclared type `MockLeaser`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockLeaser` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:331:13
[INFO] [stdout]     |
[INFO] [stdout] 331 |             MockLeaser::eo_extend(self, ack_ids).await
[INFO] [stdout]     |             ^^^^^^^^^^ use of undeclared type `MockLeaser`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockBackoffPolicy` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:564:32
[INFO] [stdout]     |
[INFO] [stdout] 564 |         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout]     |                                ^^^^^^^^^^^^^^^^^ use of undeclared type `MockBackoffPolicy`
[INFO] [stdout]     |
[INFO] [stdout] help: a trait with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 564 -         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout] 564 +         let mut mock_backoff = BackoffPolicy::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockBackoffPolicy` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:676:32
[INFO] [stdout]     |
[INFO] [stdout] 676 |         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout]     |                                ^^^^^^^^^^^^^^^^^ use of undeclared type `MockBackoffPolicy`
[INFO] [stdout]     |
[INFO] [stdout] help: a trait with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 676 -         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout] 676 +         let mut mock_backoff = BackoffPolicy::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockBackoffPolicy` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:727:32
[INFO] [stdout]     |
[INFO] [stdout] 727 |         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout]     |                                ^^^^^^^^^^^^^^^^^ use of undeclared type `MockBackoffPolicy`
[INFO] [stdout]     |
[INFO] [stdout] help: a trait with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 727 -         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout] 727 +         let mut mock_backoff = BackoffPolicy::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:758:9
[INFO] [stdout]     |
[INFO] [stdout] 758 |         for (ack_id, result) in &confirmed_nacks {
[INFO] [stdout]     |         ^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockBackoffPolicy` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:803:32
[INFO] [stdout]     |
[INFO] [stdout] 803 |         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout]     |                                ^^^^^^^^^^^^^^^^^ use of undeclared type `MockBackoffPolicy`
[INFO] [stdout]     |
[INFO] [stdout] help: a trait with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 803 -         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout] 803 +         let mut mock_backoff = BackoffPolicy::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MockBackoffPolicy` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:854:32
[INFO] [stdout]     |
[INFO] [stdout] 854 |         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout]     |                                ^^^^^^^^^^^^^^^^^ use of undeclared type `MockBackoffPolicy`
[INFO] [stdout]     |
[INFO] [stdout] help: a trait with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 854 -         let mut mock_backoff = MockBackoffPolicy::new();
[INFO] [stdout] 854 +         let mut mock_backoff = BackoffPolicy::new();
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:885:9
[INFO] [stdout]     |
[INFO] [stdout] 885 |         for (ack_id, result) in &confirmed_extends {
[INFO] [stdout]     |         ^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/retry_policy.rs:351:9
[INFO] [stdout]     |
[INFO] [stdout] 351 |         verify_exactly_once_options(super::eo_ack_options(), Duration::from_secs(600));
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/retry_policy.rs:357:9
[INFO] [stdout]     |
[INFO] [stdout] 357 |         verify_exactly_once_options(super::eo_modack_options(time_limit), time_limit);
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `start_paused` found for struct `tokio::runtime::Builder` in the current scope
[INFO] [stdout]    --> src/subscriber/shutdown_token.rs:105:9
[INFO] [stdout]     |
[INFO] [stdout] 105 |         Ok(())
[INFO] [stdout]     |         ^^ private field, not a method
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/builder.rs:422:27
[INFO] [stdout]     |
[INFO] [stdout] 422 |     async fn builder() -> anyhow::Result<()> {
[INFO] [stdout]     |                           ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/builder.rs:437:36
[INFO] [stdout]     |
[INFO] [stdout] 437 |     async fn default_batching() -> anyhow::Result<()> {
[INFO] [stdout]     |                                    ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/builder.rs:498:56
[INFO] [stdout]     |
[INFO] [stdout] 498 |     async fn publisher_builder_sets_client_config() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                        ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:693:10
[INFO] [stdout]     |
[INFO] [stdout] 693 |     ) -> anyhow::Result<()> {
[INFO] [stdout]     |          ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:302:50
[INFO] [stdout]     |
[INFO] [stdout] 302 |     async fn publisher_publish_successfully() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                  ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/transport.rs:181:31
[INFO] [stdout]     |
[INFO] [stdout] 181 |     async fn acknowledge() -> anyhow::Result<()> {
[INFO] [stdout]     |                               ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:334:59
[INFO] [stdout]     |
[INFO] [stdout] 334 |     async fn publisher_publish_successfully_with_arc() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                           ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/transport.rs:165:39
[INFO] [stdout]     |
[INFO] [stdout] 165 |     async fn modify_ack_deadline() -> anyhow::Result<()> {
[INFO] [stdout]     |                                       ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:367:51
[INFO] [stdout]     |
[INFO] [stdout] 367 |     async fn publisher_publish_large_message() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                   ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:634:33
[INFO] [stdout]     |
[INFO] [stdout] 634 |     async fn basic_success() -> anyhow::Result<()> {
[INFO] [stdout]     |                                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:384:61
[INFO] [stdout]     |
[INFO] [stdout] 384 |     async fn worker_handles_forced_shutdown_gracefully() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                             ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:578:35
[INFO] [stdout]     |
[INFO] [stdout] 578 |     async fn initial_request() -> anyhow::Result<()> {
[INFO] [stdout]     |                                   ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:414:63
[INFO] [stdout]     |
[INFO] [stdout] 414 |     async fn dropping_publisher_flushes_pending_messages() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                               ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/transport.rs:120:34
[INFO] [stdout]     |
[INFO] [stdout] 120 |     async fn streaming_pull() -> anyhow::Result<()> {
[INFO] [stdout]     |                                  ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:454:52
[INFO] [stdout]     |
[INFO] [stdout] 454 |     async fn publisher_handles_publish_errors() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                    ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/transport.rs:103:50
[INFO] [stdout]     |
[INFO] [stdout] 103 |     async fn test_transport(endpoint: String) -> anyhow::Result<Transport> {
[INFO] [stdout]     |                                                  ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:486:60
[INFO] [stdout]     |
[INFO] [stdout] 486 |     async fn flush_sends_pending_messages_immediately() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                            ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:732:46
[INFO] [stdout]     |
[INFO] [stdout] 732 |     async fn basic_success_exactly_once() -> anyhow::Result<()> {
[INFO] [stdout]     |                                              ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:532:64
[INFO] [stdout]     |
[INFO] [stdout] 532 |     async fn dropping_handles_does_not_prevent_publishing() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                                ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/stream.rs:349:48
[INFO] [stdout]     |
[INFO] [stdout] 349 |     async fn retry_then_permanent_failure() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:566:50
[INFO] [stdout]     |
[INFO] [stdout] 566 |     async fn flush_with_no_messages_is_noop() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                  ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:558:47
[INFO] [stdout]     |
[INFO] [stdout] 558 |     async fn permanent_error_ends_stream() -> anyhow::Result<()> {
[INFO] [stdout]     |                                               ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:580:66
[INFO] [stdout]     |
[INFO] [stdout] 580 |     async fn batch_sends_on_message_count_threshold_success() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                                  ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:792:42
[INFO] [stdout]     |
[INFO] [stdout] 792 |     async fn basic_lease_management() -> anyhow::Result<()> {
[INFO] [stdout]     |                                          ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:614:64
[INFO] [stdout]     |
[INFO] [stdout] 614 |     async fn batch_sends_on_message_count_threshold_error() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                                ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/stream.rs:302:38
[INFO] [stdout]     |
[INFO] [stdout] 302 |     async fn retry_then_success() -> anyhow::Result<()> {
[INFO] [stdout]     |                                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:647:49
[INFO] [stdout]     |
[INFO] [stdout] 647 |     async fn batch_sends_on_byte_threshold() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/stream.rs:286:25
[INFO] [stdout]     |
[INFO] [stdout] 286 |     async fn error() -> anyhow::Result<()> {
[INFO] [stdout]     |                         ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:680:50
[INFO] [stdout]     |
[INFO] [stdout] 680 |     async fn batch_sends_on_delay_threshold() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                  ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/stream.rs:241:30
[INFO] [stdout]     |
[INFO] [stdout] 241 |     async fn keepalives() -> anyhow::Result<()> {
[INFO] [stdout]     |                              ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:731:54
[INFO] [stdout]     |
[INFO] [stdout] 731 |     async fn batching_separates_by_ordering_key() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:534:41
[INFO] [stdout]     |
[INFO] [stdout] 534 |     async fn error_starting_stream() -> anyhow::Result<()> {
[INFO] [stdout]     |                                         ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:778:55
[INFO] [stdout]     |
[INFO] [stdout] 778 |     async fn batching_handles_empty_ordering_key() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                       ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/stream.rs:217:27
[INFO] [stdout]     |
[INFO] [stdout] 217 |     async fn success() -> anyhow::Result<()> {
[INFO] [stdout]     |                           ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:823:64
[INFO] [stdout]     |
[INFO] [stdout] 823 |     async fn ordering_key_limits_to_one_outstanding_batch() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                                ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]   --> src/subscriber/shutdown_token.rs:66:28
[INFO] [stdout]    |
[INFO] [stdout] 66 |     async fn shutdown() -> anyhow::Result<()> {
[INFO] [stdout]    |                            ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:883:64
[INFO] [stdout]     |
[INFO] [stdout] 883 |     async fn empty_ordering_key_allows_concurrent_batches() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                                ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1857:67
[INFO] [stdout]      |
[INFO] [stdout] 1857 |     async fn drop_cancels(shutdown_behavior: ShutdownBehavior) -> anyhow::Result<()> {
[INFO] [stdout]      |                                                                   ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:936:55
[INFO] [stdout]     |
[INFO] [stdout] 936 |     async fn ordering_key_error_pauses_publisher() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                       ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1809:10
[INFO] [stdout]      |
[INFO] [stdout] 1809 |     ) -> anyhow::Result<()> {
[INFO] [stdout]      |          ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client.rs:987:51
[INFO] [stdout]     |
[INFO] [stdout] 987 |     async fn batch_error_pauses_ordering_key() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                   ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1750:76
[INFO] [stdout]      |
[INFO] [stdout] 1750 |     async fn shutdown_without_next(shutdown_behavior: ShutdownBehavior) -> anyhow::Result<()> {
[INFO] [stdout]      |                                                                            ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/publisher/client.rs:1020:62
[INFO] [stdout]      |
[INFO] [stdout] 1020 |     async fn flush_on_paused_ordering_key_returns_error() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                              ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1686:36
[INFO] [stdout]      |
[INFO] [stdout] 1686 |     async fn cancel_midstream() -> anyhow::Result<()> {
[INFO] [stdout]      |                                    ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/publisher/client.rs:1057:60
[INFO] [stdout]      |
[INFO] [stdout] 1057 |     async fn resuming_non_paused_ordering_key_is_noop() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                            ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1667:38
[INFO] [stdout]      |
[INFO] [stdout] 1667 |     async fn cancel_before_open() -> anyhow::Result<()> {
[INFO] [stdout]      |                                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/publisher/client.rs:1088:66
[INFO] [stdout]      |
[INFO] [stdout] 1088 |     async fn resuming_paused_ordering_key_allows_publishing() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                                  ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1612:50
[INFO] [stdout]      |
[INFO] [stdout] 1612 |     async fn at_least_once_and_exactly_once() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                  ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/publisher/client.rs:1127:55
[INFO] [stdout]      |
[INFO] [stdout] 1127 |     async fn resuming_ordering_key_twice_is_safe() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                       ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1572:48
[INFO] [stdout]      |
[INFO] [stdout] 1572 |     async fn shutdown_wait_for_processing() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/publisher/client.rs:1165:68
[INFO] [stdout]      |
[INFO] [stdout] 1165 |     async fn resuming_one_ordering_key_does_not_resume_others() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                                    ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1509:42
[INFO] [stdout]      |
[INFO] [stdout] 1509 |     async fn basic_lease_expiration() -> anyhow::Result<()> {
[INFO] [stdout]      |                                          ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/publisher/client.rs:1211:61
[INFO] [stdout]      |
[INFO] [stdout] 1211 |     async fn publisher_builder_clamps_batching_options() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                             ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:525:47
[INFO] [stdout]     |
[INFO] [stdout] 525 |     async fn test_client(endpoint: String) -> anyhow::Result<Subscriber> {
[INFO] [stdout]     |                                               ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:700:25
[INFO] [stdout]     |
[INFO] [stdout] 700 |     async fn basic() -> anyhow::Result<()> {
[INFO] [stdout]     |                         ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1296:55
[INFO] [stdout]      |
[INFO] [stdout] 1296 |     async fn limit_size_of_extends_at_least_once() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                       ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:718:44
[INFO] [stdout]     |
[INFO] [stdout] 718 |     async fn concurrent_actor_publish() -> anyhow::Result<()> {
[INFO] [stdout]     |                                            ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1435:34
[INFO] [stdout]      |
[INFO] [stdout] 1435 |     async fn routing_header() -> anyhow::Result<()> {
[INFO] [stdout]      |                                  ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:754:44
[INFO] [stdout]     |
[INFO] [stdout] 754 |     async fn sequential_actor_publish() -> anyhow::Result<()> {
[INFO] [stdout]     |                                            ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1361:57
[INFO] [stdout]      |
[INFO] [stdout] 1361 |     async fn resume_midstream_hits_permanent_error() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                         ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:795:42
[INFO] [stdout]     |
[INFO] [stdout] 795 |     async fn concurrent_actor_flush() -> anyhow::Result<()> {
[INFO] [stdout]     |                                          ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1290:44
[INFO] [stdout]      |
[INFO] [stdout] 1290 |     async fn resume_midstream_success() -> anyhow::Result<()> {
[INFO] [stdout]      |                                            ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:839:42
[INFO] [stdout]     |
[INFO] [stdout] 839 |     async fn sequential_actor_flush() -> anyhow::Result<()> {
[INFO] [stdout]     |                                          ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1240:56
[INFO] [stdout]      |
[INFO] [stdout] 1240 |     async fn retry_transient_when_starting_stream() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                        ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:888:43
[INFO] [stdout]     |
[INFO] [stdout] 888 |     async fn concurrent_actor_resume() -> anyhow::Result<()> {
[INFO] [stdout]     |                                           ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:839:46
[INFO] [stdout]     |
[INFO] [stdout] 839 |     async fn eo_extend_retry_time_limit() -> anyhow::Result<()> {
[INFO] [stdout]     |                                              ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:905:43
[INFO] [stdout]     |
[INFO] [stdout] 905 |     async fn sequential_actor_resume() -> anyhow::Result<()> {
[INFO] [stdout]     |                                           ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1219:40
[INFO] [stdout]      |
[INFO] [stdout] 1219 |     async fn no_immediate_message() -> anyhow::Result<()> {
[INFO] [stdout]      |                                        ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:970:66
[INFO] [stdout]     |
[INFO] [stdout] 970 |     async fn concurrent_actor_batch_message_count_threshold() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                                  ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1150:29
[INFO] [stdout]      |
[INFO] [stdout] 1150 |     async fn client_id() -> anyhow::Result<()> {
[INFO] [stdout]      |                             ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/actor.rs:995:66
[INFO] [stdout]     |
[INFO] [stdout] 995 |     async fn sequential_actor_batch_message_count_threshold() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                                  ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1093:30
[INFO] [stdout]      |
[INFO] [stdout] 1093 |     async fn keepalives() -> anyhow::Result<()> {
[INFO] [stdout]      |                              ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/publisher/actor.rs:1019:57
[INFO] [stdout]      |
[INFO] [stdout] 1019 |     async fn concurrent_actor_byte_count_threshold() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                         ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/message_stream.rs:1053:45
[INFO] [stdout]      |
[INFO] [stdout] 1053 |     async fn permanent_error_midstream() -> anyhow::Result<()> {
[INFO] [stdout]      |                                             ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/publisher/actor.rs:1058:57
[INFO] [stdout]      |
[INFO] [stdout] 1058 |     async fn sequential_actor_byte_count_threshold() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                         ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:986:49
[INFO] [stdout]     |
[INFO] [stdout] 986 |     async fn handles_missing_message_field() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/publisher/actor.rs:1097:55
[INFO] [stdout]      |
[INFO] [stdout] 1097 |     async fn sequential_actor_send_large_message() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                       ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:954:42
[INFO] [stdout]     |
[INFO] [stdout] 954 |     async fn handles_empty_response() -> anyhow::Result<()> {
[INFO] [stdout]     |                                          ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/publisher/actor.rs:1131:55
[INFO] [stdout]      |
[INFO] [stdout] 1131 |     async fn concurrent_actor_send_large_message() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                       ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:921:47
[INFO] [stdout]     |
[INFO] [stdout] 921 |     async fn serves_messages_immediately() -> anyhow::Result<()> {
[INFO] [stdout]     |                                               ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]   --> src/publisher/base_publisher.rs:97:27
[INFO] [stdout]    |
[INFO] [stdout] 97 |     async fn builder() -> anyhow::Result<()> {
[INFO] [stdout]    |                           ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/batch.rs:155:45
[INFO] [stdout]     |
[INFO] [stdout] 155 |     async fn test_push_and_flush_batch() -> anyhow::Result<()> {
[INFO] [stdout]     |                                             ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:893:32
[INFO] [stdout]     |
[INFO] [stdout] 893 |         let handle: JoinHandle<anyhow::Result<()>> = tokio::spawn(async move {
[INFO] [stdout]     |                                ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/batch.rs:185:29
[INFO] [stdout]     |
[INFO] [stdout] 185 |     async fn test_size() -> anyhow::Result<()> {
[INFO] [stdout]     |                             ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/message_stream.rs:888:37
[INFO] [stdout]     |
[INFO] [stdout] 888 |     async fn delayed_responses() -> anyhow::Result<()> {
[INFO] [stdout]     |                                     ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client_builder.rs:237:22
[INFO] [stdout]     |
[INFO] [stdout] 237 |     fn defaults() -> anyhow::Result<()> {
[INFO] [stdout]     |                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/publisher/client_builder.rs:268:27
[INFO] [stdout]     |
[INFO] [stdout] 268 |     async fn setters() -> anyhow::Result<()> {
[INFO] [stdout]     |                           ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]   --> src/publisher/future.rs:74:50
[INFO] [stdout]    |
[INFO] [stdout] 74 |     async fn resolve_publish_future_success() -> anyhow::Result<()> {
[INFO] [stdout]    |                                                  ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]   --> src/publisher/future.rs:84:48
[INFO] [stdout]    |
[INFO] [stdout] 84 |     async fn resolve_publish_future_error() -> anyhow::Result<()> {
[INFO] [stdout]    |                                                ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]   --> src/publisher/future.rs:98:59
[INFO] [stdout]    |
[INFO] [stdout] 98 |     async fn resolve_publish_future_error_send_error() -> anyhow::Result<()> {
[INFO] [stdout]    |                                                           ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]   --> src/publisher/options.rs:64:36
[INFO] [stdout]    |
[INFO] [stdout] 64 |     async fn batching_options() -> anyhow::Result<()> {
[INFO] [stdout]    |                                    ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:524:38
[INFO] [stdout]     |
[INFO] [stdout] 524 |     fn handler_delivery_attempt() -> anyhow::Result<()> {
[INFO] [stdout]     |                                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:532:44
[INFO] [stdout]     |
[INFO] [stdout] 532 |     fn at_least_once_delivery_attempt() -> anyhow::Result<()> {
[INFO] [stdout]     |                                            ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:540:49
[INFO] [stdout]     |
[INFO] [stdout] 540 |     fn at_least_once_delivery_attempt_none() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:548:43
[INFO] [stdout]     |
[INFO] [stdout] 548 |     fn exactly_once_delivery_attempt() -> anyhow::Result<()> {
[INFO] [stdout]     |                                           ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:557:48
[INFO] [stdout]     |
[INFO] [stdout] 557 |     fn exactly_once_delivery_attempt_none() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:566:39
[INFO] [stdout]     |
[INFO] [stdout] 566 |     fn handler_at_least_once_ack() -> anyhow::Result<()> {
[INFO] [stdout]     |                                       ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:579:40
[INFO] [stdout]     |
[INFO] [stdout] 579 |     fn handler_at_least_once_nack() -> anyhow::Result<()> {
[INFO] [stdout]     |                                        ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:592:38
[INFO] [stdout]     |
[INFO] [stdout] 592 |     fn handler_exactly_once_ack() -> anyhow::Result<()> {
[INFO] [stdout]     |                                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:606:39
[INFO] [stdout]     |
[INFO] [stdout] 606 |     fn handler_exactly_once_nack() -> anyhow::Result<()> {
[INFO] [stdout]     |                                       ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:620:31
[INFO] [stdout]     |
[INFO] [stdout] 620 |     fn at_least_once_ack() -> anyhow::Result<()> {
[INFO] [stdout]     |                               ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:633:32
[INFO] [stdout]     |
[INFO] [stdout] 633 |     fn at_least_once_nack() -> anyhow::Result<()> {
[INFO] [stdout]     |                                ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:646:30
[INFO] [stdout]     |
[INFO] [stdout] 646 |     fn exactly_once_ack() -> anyhow::Result<()> {
[INFO] [stdout]     |                              ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:660:40
[INFO] [stdout]     |
[INFO] [stdout] 660 |     async fn exactly_once_success() -> anyhow::Result<()> {
[INFO] [stdout]     |                                        ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:680:45
[INFO] [stdout]     |
[INFO] [stdout] 680 |     async fn exactly_once_nack_success() -> anyhow::Result<()> {
[INFO] [stdout]     |                                             ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:700:38
[INFO] [stdout]     |
[INFO] [stdout] 700 |     async fn exactly_once_error() -> anyhow::Result<()> {
[INFO] [stdout]     |                                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:721:43
[INFO] [stdout]     |
[INFO] [stdout] 721 |     async fn exactly_once_nack_error() -> anyhow::Result<()> {
[INFO] [stdout]     |                                           ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:742:54
[INFO] [stdout]     |
[INFO] [stdout] 742 |     async fn exactly_once_action_channel_closed() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:756:59
[INFO] [stdout]     |
[INFO] [stdout] 756 |     async fn exactly_once_nack_action_channel_closed() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                           ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:776:54
[INFO] [stdout]     |
[INFO] [stdout] 776 |     async fn exactly_once_result_channel_closed() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:795:31
[INFO] [stdout]     |
[INFO] [stdout] 795 |     fn exactly_once_nack() -> anyhow::Result<()> {
[INFO] [stdout]     |                               ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:809:48
[INFO] [stdout]     |
[INFO] [stdout] 809 |     fn handler_at_least_once_nack_on_drop() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:822:47
[INFO] [stdout]     |
[INFO] [stdout] 822 |     fn handler_exactly_once_nack_on_drop() -> anyhow::Result<()> {
[INFO] [stdout]     |                                               ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:836:40
[INFO] [stdout]     |
[INFO] [stdout] 836 |     fn at_least_once_nack_on_drop() -> anyhow::Result<()> {
[INFO] [stdout]     |                                        ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/handler.rs:849:39
[INFO] [stdout]     |
[INFO] [stdout] 849 |     fn exactly_once_nack_on_drop() -> anyhow::Result<()> {
[INFO] [stdout]     |                                       ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/builder.rs:226:30
[INFO] [stdout]     |
[INFO] [stdout] 226 |     async fn test_inner() -> anyhow::Result<Arc<Transport>> {
[INFO] [stdout]     |                              ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/builder.rs:234:39
[INFO] [stdout]     |
[INFO] [stdout] 234 |     async fn reasonable_defaults() -> anyhow::Result<()> {
[INFO] [stdout]     |                                       ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/builder.rs:271:27
[INFO] [stdout]     |
[INFO] [stdout] 271 |     async fn options() -> anyhow::Result<()> {
[INFO] [stdout]     |                           ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/builder.rs:301:60
[INFO] [stdout]     |
[INFO] [stdout] 301 |     async fn clamp_ack_deadline(v: Duration, want: i32) -> anyhow::Result<()> {
[INFO] [stdout]     |                                                            ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/client.rs:185:25
[INFO] [stdout]     |
[INFO] [stdout] 185 |     async fn basic() -> anyhow::Result<()> {
[INFO] [stdout]     |                         ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/client.rs:191:34
[INFO] [stdout]     |
[INFO] [stdout] 191 |     async fn streaming_pull() -> anyhow::Result<()> {
[INFO] [stdout]     |                                  ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/client.rs:220:41
[INFO] [stdout]     |
[INFO] [stdout] 220 |     async fn grpc_subchannel_count() -> anyhow::Result<()> {
[INFO] [stdout]     |                                         ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:324:10
[INFO] [stdout]     |
[INFO] [stdout] 324 |     ) -> anyhow::Result<()> {
[INFO] [stdout]     |          ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:346:10
[INFO] [stdout]     |
[INFO] [stdout] 346 |     ) -> anyhow::Result<()> {
[INFO] [stdout]     |          ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:384:10
[INFO] [stdout]     |
[INFO] [stdout] 384 |     ) -> anyhow::Result<()> {
[INFO] [stdout]     |          ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:426:10
[INFO] [stdout]     |
[INFO] [stdout] 426 |     ) -> anyhow::Result<()> {
[INFO] [stdout]     |          ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:470:10
[INFO] [stdout]     |
[INFO] [stdout] 470 |     ) -> anyhow::Result<()> {
[INFO] [stdout]     |          ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:490:51
[INFO] [stdout]     |
[INFO] [stdout] 490 |     async fn exactly_once_retry_loop_success() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                   ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1343:54
[INFO] [stdout]      |
[INFO] [stdout] 1343 |     async fn limit_size_of_extends_exactly_once() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:529:51
[INFO] [stdout]     |
[INFO] [stdout] 529 |     async fn exactly_once_retry_loop_failure() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                   ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:771:35
[INFO] [stdout]     |
[INFO] [stdout] 771 |     async fn eo_extend_retry() -> anyhow::Result<()> {
[INFO] [stdout]     |                                   ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:578:83
[INFO] [stdout]     |
[INFO] [stdout] 578 |     async fn exactly_once_retry_loop_partial_transient_failure_retry_success() -> anyhow::Result<()>
[INFO] [stdout]     |                                                                                   ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1389:52
[INFO] [stdout]      |
[INFO] [stdout] 1389 |     async fn message_expiration_at_least_once() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                    ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:712:51
[INFO] [stdout]     |
[INFO] [stdout] 712 |     async fn confirmed_nack_retry_time_limit() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                   ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:629:83
[INFO] [stdout]     |
[INFO] [stdout] 629 |     async fn exactly_once_retry_loop_partial_transient_failure_retry_failure() -> anyhow::Result<()>
[INFO] [stdout]     |                                                                                   ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]     --> src/subscriber/lease_state.rs:1436:51
[INFO] [stdout]      |
[INFO] [stdout] 1436 |     async fn message_expiration_exactly_once() -> anyhow::Result<()> {
[INFO] [stdout]      |                                                   ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]      |
[INFO] [stdout]      = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:644:40
[INFO] [stdout]     |
[INFO] [stdout] 644 |     async fn confirmed_nack_retry() -> anyhow::Result<()> {
[INFO] [stdout]     |                                        ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:693:69
[INFO] [stdout]     |
[INFO] [stdout] 693 |     async fn exactly_once_retry_loop_partial_permanent_failure() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                                     ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:600:34
[INFO] [stdout]     |
[INFO] [stdout] 600 |     async fn confirmed_nack() -> anyhow::Result<()> {
[INFO] [stdout]     |                                  ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/exactly_once_retry.rs:739:53
[INFO] [stdout]     |
[INFO] [stdout] 739 |     async fn exactly_once_retry_loop_exhausted() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                     ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:493:33
[INFO] [stdout]     |
[INFO] [stdout] 493 |     async fn confirmed_ack() -> anyhow::Result<()> {
[INFO] [stdout]     |                                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/leaser.rs:534:39
[INFO] [stdout]     |
[INFO] [stdout] 534 |     async fn confirmed_ack_retry() -> anyhow::Result<()> {
[INFO] [stdout]     |                                       ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]   --> src/subscriber/keepalive.rs:79:40
[INFO] [stdout]    |
[INFO] [stdout] 79 |     async fn shutdown_immediately() -> anyhow::Result<()> {
[INFO] [stdout]    |                                        ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:193:38
[INFO] [stdout]     |
[INFO] [stdout] 193 |     async fn basic_exactly_once() -> anyhow::Result<()> {
[INFO] [stdout]     |                                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:253:33
[INFO] [stdout]     |
[INFO] [stdout] 253 |     async fn confirmed_ack() -> anyhow::Result<()> {
[INFO] [stdout]     |                                 ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:300:48
[INFO] [stdout]     |
[INFO] [stdout] 300 |     async fn flush_acks_nacks_on_interval() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:401:35
[INFO] [stdout]     |
[INFO] [stdout] 401 |     async fn extend_interval() -> anyhow::Result<()> {
[INFO] [stdout]     |                                   ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:522:61
[INFO] [stdout]     |
[INFO] [stdout] 522 |     async fn drop_does_not_wait_for_pending_operations() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                             ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:556:45
[INFO] [stdout]     |
[INFO] [stdout] 556 |     async fn shutdown_nack_immediately() -> anyhow::Result<()> {
[INFO] [stdout]     |                                             ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:603:48
[INFO] [stdout]     |
[INFO] [stdout] 603 |     async fn shutdown_wait_for_processing() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:651:79
[INFO] [stdout]     |
[INFO] [stdout] 651 |     async fn shutdown_waits_for_flush(shutdown_behavior: ShutdownBehavior) -> anyhow::Result<()> {
[INFO] [stdout]     |                                                                               ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:706:39
[INFO] [stdout]     |
[INFO] [stdout] 706 |     async fn no_add_and_ack_race() -> anyhow::Result<()> {
[INFO] [stdout]     |                                       ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_loop.rs:765:56
[INFO] [stdout]     |
[INFO] [stdout] 765 |     async fn eo_extend_result_updates_lease_state() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                        ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_state/at_least_once.rs:494:22
[INFO] [stdout]     |
[INFO] [stdout] 494 |     fn batching() -> anyhow::Result<()> {
[INFO] [stdout]     |                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_state/at_least_once.rs:520:38
[INFO] [stdout]     |
[INFO] [stdout] 520 |     async fn message_expiration() -> anyhow::Result<()> {
[INFO] [stdout]     |                                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_state/at_least_once.rs:579:40
[INFO] [stdout]     |
[INFO] [stdout] 579 |     async fn necessary_extensions() -> anyhow::Result<()> {
[INFO] [stdout]     |                                        ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_state/exactly_once.rs:349:27
[INFO] [stdout]     |
[INFO] [stdout] 349 |     async fn confirm() -> anyhow::Result<()> {
[INFO] [stdout]     |                           ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_state/exactly_once.rs:576:22
[INFO] [stdout]     |
[INFO] [stdout] 576 |     fn batching() -> anyhow::Result<()> {
[INFO] [stdout]     |                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_state/exactly_once.rs:603:38
[INFO] [stdout]     |
[INFO] [stdout] 603 |     async fn message_expiration() -> anyhow::Result<()> {
[INFO] [stdout]     |                                      ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_state/exactly_once.rs:675:46
[INFO] [stdout]     |
[INFO] [stdout] 675 |     async fn pending_acks_do_not_expire() -> anyhow::Result<()> {
[INFO] [stdout]     |                                              ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_state/exactly_once.rs:719:53
[INFO] [stdout]     |
[INFO] [stdout] 719 |     async fn nacking_messages_are_not_extended() -> anyhow::Result<()> {
[INFO] [stdout]     |                                                     ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_state/exactly_once.rs:766:25
[INFO] [stdout]     |
[INFO] [stdout] 766 |     async fn evict() -> anyhow::Result<()> {
[INFO] [stdout]     |                         ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_state/exactly_once.rs:836:42
[INFO] [stdout]     |
[INFO] [stdout] 836 |     async fn evict_overflow_batches() -> anyhow::Result<()> {
[INFO] [stdout]     |                                          ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `anyhow` in this scope
[INFO] [stdout]    --> src/subscriber/lease_state/exactly_once.rs:857:40
[INFO] [stdout]     |
[INFO] [stdout] 857 |     async fn necessary_extensions() -> anyhow::Result<()> {
[INFO] [stdout]     |                                        ^^^^^^ use of unresolved module or unlinked crate `anyhow`
[INFO] [stdout]     |
[INFO] [stdout]     = help: if you wanted to use a crate named `anyhow`, use `cargo add anyhow` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0308, E0425, E0432, E0433, E0599.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0308`.
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `google-cloud-pubsub` (lib test) due to 376 previous errors; 5 warnings emitted
[INFO] running `Command { std: "docker" "inspect" "76adf9c26249b57c13daea1b47f53b8893dd92750699a755d208547f0acfb7a6", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "76adf9c26249b57c13daea1b47f53b8893dd92750699a755d208547f0acfb7a6", kill_on_drop: false }`
[INFO] [stdout] 76adf9c26249b57c13daea1b47f53b8893dd92750699a755d208547f0acfb7a6
